package com.tth.learn.addproperties.java2;

import com.tth.learn.addproperties.java1.Person;
import org.junit.Test;

import java.util.Arrays;
import java.util.List;
import java.util.Optional;
import java.util.Set;
import java.util.stream.Collectors;

/**
 * 测试Stream的终止操作
 * @Author tth
 * @Date 2023/1/4 10:31
 */
public class StreamAPITest3 {

    /**
     * 匹配与查找
     */
    @Test
    public void test1() {
        List<Person> persons = Person.getPersons();

        // 练习：判断是否所有人员的年龄都不小于16岁
        boolean allMatch = persons.stream().allMatch(p -> p.getAge() >= 16);
        System.out.println(allMatch);

        System.out.println("**************************************************************************");

        // 练习：判断是否存在人员的工资大于10000
        boolean anyMatch = persons.stream().anyMatch(p -> p.getSalary() > 10000);
        System.out.println(anyMatch);

        System.out.println("**************************************************************************");

        // 练习：判断是否存在人员姓“诸葛”
        // noneMatch：检查是否没有匹配的元素。如果有姓“诸葛”的，返回false；否则返回true
        boolean noneMatch = persons.stream().noneMatch(p -> p.getName().startsWith("诸葛"));
        System.out.println(noneMatch);

        System.out.println("**************************************************************************");

        // 练习：返回第一个人员信息
        // Optional类是用来处理空指针类型的。后边讲
        Optional<Person> first = persons.stream().findFirst();
        System.out.println(first);

        System.out.println("**************************************************************************");

        // 练习：随机返回一个人员信息
        // 注意：使用findAny()时，在获取Stream实例的时候，最好用List.parallelStream()，才会随机返回一个。使用List.stream()只能返回第一个
        Optional<Person> any2 = persons.parallelStream().findAny();
        System.out.println(any2);

        System.out.println("**************************************************************************");

        // 练习：求人员列表中年龄在18岁以下的人员的个数
        long count = persons.stream().filter(person -> person.getAge() < 18).count();
        System.out.println(count);

        System.out.println("**************************************************************************");

        // 练习：返回最高的工资
        Optional<Double> max = persons.stream().map(person -> person.getSalary()).max(Double::compareTo);
        System.out.println(max);

        System.out.println("**************************************************************************");

        // 练习：返回最低工资的员工
        Optional<Person> minSalaryPerson = persons.stream().min((p1, p2) -> Double.compare(p1.getSalary(), p2.getSalary()));
        System.out.println(minSalaryPerson);

        System.out.println("**************************************************************************");

        // 练习：内部迭代
        persons.stream().forEach(System.out :: println);
    }

    /**
     * 规约
     */
    @Test
    public void test2() {
        // 练习1：计算1-10的自然数的值
        List<Integer> list = Arrays.asList(1, 2, 3, 4, 5, 6, 7, 8, 9, 10);
        Integer sum = list.stream().reduce(0, Integer::sum);
        System.out.println(sum);

        // 练习2：计算人员工资的总和
        List<Person> persons = Person.getPersons();
        Optional<Double> reduce = persons.stream().map(person -> person.getSalary()).reduce(Double::sum);
        // 如果不知道Double.sum(double a, double b)方法，可以使用如下方法计算总和
//        Optional<Double> reduce2 = persons.stream().map(person -> person.getSalary()).reduce((d1, d2) -> d1 + d2);
        System.out.println(reduce);
    }

    /**
     * 收集
     */
    @Test
    public void test3() {
        List<Person> persons = Person.getPersons();
        // 练习： 查找工资大于6000的人员，结果返回一个List
        List<Person> collect = persons.stream().filter(person -> person.getSalary() > 6000).collect(Collectors.toList());
        System.out.println(collect);

        System.out.println();

        // 练习：查找工资大于6000的人员，结果返回一个Set
        Set<Person> collect1 = persons.stream().filter(person -> person.getSalary() > 6000).collect(Collectors.toSet());
        System.out.println(collect1);
    }
}
